package com.california.payopenapi.common;


import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class IThreadPool extends ThreadPoolExecutor {

    public IThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }


    /**
     * 线程池异常处理
     */
    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        t.printStackTrace();
    }
}